<?php

namespace process;

use app\common\lib\CommandUtil;
use Workerman\Crontab\Crontab;

class Task
{
    public function onWorkerStart()
    {
        // 每5秒执行一次
        // pcntl_alarm
//        new Crontab('*/5 * * * * *', function(){
////            echo date('Y-m-d H:i:s')."\n";
//
//            $sendMsgModel = new \app\common\model\SendMsg();
//
//            $sendMsg = $sendMsgModel->connect('plugin.admin.mysql')->field('id,title,content')->where(['status' => 1])
//                ->order(['id'=>'desc'])->find();
//            if (!empty($sendMsg)) {
//                $userFcmTokenModel = new \app\common\model\UserFcmToken();
//                $users = $userFcmTokenModel->connect('plugin.admin.mysql')->field('id,user_id,fcm_token')
//                    ->where([['exp_time', '>', time()-(30*86400)]])
//                    ->cursor();
//                if (!empty($users)) {
//                    $fcmMessageBus = new \app\common\business\sendFcm\FcmMessage();
//                    foreach ($users as $key=>$user) {
//                        if (isset($users[$key+1])) {
//                            $fcmMessageBus::fcmSend($user, $sendMsg, false);
//                        } else {
//                            $fcmMessageBus::fcmSend($user, $sendMsg);
//                        }
//                    }
//                }
//            }
//            echo 'SUCCESS';
//        });

//        // 每分钟执行一次
//        new Crontab('0 */1 * * * *', function(){
//            echo date('Y-m-d')."\n";
//        });
//
//        // 每天的7点50执行，注意这里省略了秒位
//        new Crontab('50 7 * * *', function(){
//            echo date('Y-m-d H:i:s')."\n";
//        });
    }
}
